#include "publisher.h"
#include <iostream>
#include <thread>
#include <chrono>

PublisherEndpoint::PublisherEndpoint(const std::string& address, bool bind) {
    context = zmq::context_t();  // 使用默认构造函数初始化 context
    publisher = zmq::socket_t(context, zmq::socket_type::pub);  // 使用 context 初始化 publisher
    if (bind) {
        publisher.bind(address);  // 绑定地址
    } else {
        publisher.connect(address);  // 连接地址
    }
}

void PublisherEndpoint::publish(const std::string& message) {
    publisher.send(zmq::buffer(message), zmq::send_flags::none);  // 发送消息
    std::cout << "Published: " << message << std::endl;
}
